package Flink;

import org.apache.flink.streaming.api.windowing.windows.TimeWindow;

/**
 * 测试窗口开始时间
 * @Author: leiwenkang02
 * @Date: 2020/3/14 7:44 下午
 */
public class FunctionTest {
    public static void main(String[] args) {
        long time = 1584184162000L;
        long winStartTime = TimeWindow.getWindowStartWithOffset(time, 0, 3000);
        System.out.println(TimeUtil.getStringDate(time));
        System.out.println(TimeUtil.getStringDate(winStartTime));
    }
}
